'''
演示Socket服务端开发
'''

import socket
# 创建Socket对象
socket_server = socket.socket()
# 绑定ip地址和端口
socket_server.bind(('localhost',8888))
# 监听端口
socket_server.listen(1)  # listen方法接受一个整数参数，表示接受的链接数量
# 等待客户端链接
# result: tuple = socket_server.accept()
# conn = result[0]  # 客户端和服务端的链接对象
# address = result[1] # 客户端的地址信息
conn, address = socket_server.accept()
# accept方法，返回的是二元元组（链接对象，客户端地址信息）
# 可以通过 变量1，变量2 = socket_server.accept()的形式，直接接受二元元组内的两个元素
# accept()方法，是阻塞的方法，等待客户端的链接，如果没有链接，就卡在这一行不向下执行了
print(f"接受到了客户端的链接，客户端的信息是:{address}")

while True:
    # 接受客户端信息,要使用客户端和服务端的本次链接对象，而非socket_server对象
    data: str = conn.recv(1024).decode('utf-8')
    # recv接受的参数是缓冲区大小，一般给1024即可
    # recv方法返回值是一个字节数组也就是bytes对象，不是字符串，
    # 可以通过decode方法通过UTF-8编码，将字节数组转换为字符串对象
    print(f"客户端发来的消息是：{data}")

    # 发送回复消息
    msg = input("请输入你要和客户端回复的消息： ")  # encode可以将字符串编码为字节数组对象
    if msg == "exit":
        break
    else:
        conn.send(msg.encode('utf-8'))
# 关闭链接
conn.close()
socket_server.close()
